package com.zzyy.study.mq.service;

import com.zzyy.study.mq.po.SequentialMsgConsumePositionPO;

/**
 * 顺序消息消费信息表
 */

public interface ISequentialMsgConsumePositionService extends IBaseService<SequentialMsgConsumePositionPO> {

    /**
     * 根据 groupId  & queueName 获取记录，不存在的时候则创建
     *
     * @param groupId
     * @param queueName
     * @return
     */
    SequentialMsgConsumePositionPO getAndCreate(String groupId, String queueName);

}
